package org.ala.rpc_test.grpc;

import org.ala.rpc_test.grpc.OrderServiceImplGrpc.OrderServiceImplImplBase;

import io.grpc.stub.StreamObserver;

/**
 *
 *	@author ala
 *	@date 2025年4月23日
 */
public class OrderServiceImpl extends OrderServiceImplImplBase {
	

	@Override
	public void order(OrderDO request, StreamObserver<OrderItemDO> responseObserver) {
		OrderItemDO item = OrderItemDO.newBuilder().setId(1l).setOrderId(request.getId()).build();
		responseObserver.onNext(item);
		responseObserver.onCompleted();
	}

}
